import eventlet
# 1.
eventlet.monkey_patch()
import socketio
import eventlet.wsgi

# 2.
sio = socketio.Server(async_mode='eventlet')

# 3.
app = socketio.Middleware(sio)

# 4.监听事件
@sio.on('connect')
def on_connect(sid, environ):
    """
    :param sid:
    :param environ:
    :return:
    """
    pass
@sio.on('message')
def on_message(sid, data):
    """
        回复消息:
        和用户聊天的是机器人聊天服务，这块的内容是后面深度学习，属于自然语言处理部分。
        所以这里我们只是简单实现回复即可，后面学完深度学习再接上rpc调用。
        :param sid:
        :param data:
        :return:
    """
    msg = '我已经收到您的消息,稍后等我找到小智再回复你'
    # 回复
    sio.send(msg, room=sid)
    # 使用grpc去调用深度学习,机器人回复
    # 写proto3
# 5.创建socket对象
socket = eventlet.listen(('192.168.226.129', 8888))

# 6.启动
eventlet.wsgi.server(socket, app)